package com.ruoyi.framework.config;

import com.ruoyi.common.utils.Threads;
import org.apache.commons.lang3.concurrent.BasicThreadFactory;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;

import java.util.concurrent.Executors;
import java.util.concurrent.LinkedBlockingDeque;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.ScheduledThreadPoolExecutor;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

/**
 * 线程池配置
 *
 * @author ruoyi
 **/
@Configuration
public class ThreadPoolConfig {

    // 核心线程池大小
    private int corePoolSize = 50;

    // 最大可创建的线程数
    private int maxPoolSize = 1000;

    // 队列最大长度
    private int queueCapacity = 1000;

    // 线程池维护线程所允许的空闲时间
    private int keepAliveSeconds = 300;

    @Bean (name = "threadPoolTaskExecutor")
    public ThreadPoolTaskExecutor threadPoolTaskExecutor () {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setMaxPoolSize(this.maxPoolSize);
        executor.setCorePoolSize(this.corePoolSize);
        executor.setQueueCapacity(this.queueCapacity);
        executor.setKeepAliveSeconds(this.keepAliveSeconds);
        // 线程池对拒绝任务(无线程可用)的处理策略
        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
        return executor;
    }

    /**
     * 执行周期性或定时任务
     */
    @Bean (name = "scheduledExecutorService")
    protected ScheduledExecutorService scheduledExecutorService () {
        return new ScheduledThreadPoolExecutor(this.corePoolSize,
                new BasicThreadFactory.Builder().namingPattern("schedule-pool-%d").daemon(true).build()
        ) {
            @Override
            protected void afterExecute (Runnable r, Throwable t) {
                super.afterExecute(r, t);
                Threads.printException(r, t);
            }
        };
    }


    @Bean
    @Qualifier (value = "threadPoolExecutor")
    public ThreadPoolExecutor threadPoolExecutor () {
        return new ThreadPoolExecutor(Runtime.getRuntime().availableProcessors(),
                (int) (Runtime.getRuntime().availableProcessors() / (1 - 0.9)), 60, TimeUnit.SECONDS,
                new LinkedBlockingDeque <>(Runtime.getRuntime().availableProcessors()),
                Executors.defaultThreadFactory(), new ThreadPoolExecutor.CallerRunsPolicy()
        );
    }

    //公用线程池
    @Bean
    @Qualifier (value = "commonThreadPoolExecutor")
    public ThreadPoolExecutor commonThreadPoolExecutor () {
        return new ThreadPoolExecutor(this.corePoolSize, this.maxPoolSize, 60, TimeUnit.SECONDS,
                new LinkedBlockingDeque <>(Runtime.getRuntime().availableProcessors()),
                Executors.defaultThreadFactory(), new ThreadPoolExecutor.CallerRunsPolicy()
        );
    }

    //检查业务对应的线程池
    @Bean
    @Qualifier (value = "checkThreadPoolExecutor")
    public ThreadPoolExecutor checkThreadPoolExecutor () {
        return new ThreadPoolExecutor(this.corePoolSize, this.maxPoolSize, 60, TimeUnit.SECONDS,
                new LinkedBlockingDeque <>(Runtime.getRuntime().availableProcessors()),
                Executors.defaultThreadFactory(), new ThreadPoolExecutor.CallerRunsPolicy()
        );
    }

    //支付业务对应的线程池
    @Bean
    @Qualifier (value = "payThreadPoolExecutor")
    public ThreadPoolExecutor payThreadPoolExecutor () {
        return new ThreadPoolExecutor(this.corePoolSize, this.maxPoolSize, 60, TimeUnit.SECONDS,
                new LinkedBlockingDeque <>(Runtime.getRuntime().availableProcessors()),
                Executors.defaultThreadFactory(), new ThreadPoolExecutor.CallerRunsPolicy()
        );
    }

    //通知业务对应的线程池
    @Bean
    @Qualifier (value = "noticeThreadPoolExecutor")
    public ThreadPoolExecutor noticeThreadPoolExecutor () {
        return new ThreadPoolExecutor(this.corePoolSize, this.maxPoolSize, 60, TimeUnit.SECONDS,
                new LinkedBlockingDeque <>(Runtime.getRuntime().availableProcessors()),
                Executors.defaultThreadFactory(), new ThreadPoolExecutor.CallerRunsPolicy()
        );
    }

}
